package com.shujia.udf

import org.apache.flink.table.functions.ScalarFunction

class StrUDF extends ScalarFunction {
  def eval(str: String): String = {
    str.replaceAll("</?\\w+[^>]*>", "")
  }

}
